package com.alex.space.commons.kafka;

/**
 * @author Alex
 *         Created by Alex on 2017/12/22.
 *         <p>
 *         kafka Test main class
 */
public class KafkaConsumerProducerTest {

    public static void main(String[] args) {
        KafkaProducer producerThread = new KafkaProducer(KafkaProperties.TOPIC_1);
        producerThread.start();

        KafkaConsumer consumerThread = new KafkaConsumer(KafkaProperties.TOPIC_1);
        consumerThread.start();
    }
}
